package main

import (
	"secondbuy/RabbitMQ"
	"strconv"
	"time"
)

func main()  {
	rabbitmq := RabbitMQ.NewRabbitMQPubSub("newProduct")
	for i:= 0;i<100;i++{
		rabbitmq.PublishPub("订阅模式生产第"+strconv.Itoa(i)+"条数据")
		time.Sleep(time.Second)
	}
}
